//package com.wb3.meta.common.utils;
//
//import com.alibaba.fastjson.JSON;
//import com.cyou.sdk.msg.Message;
//import lombok.extern.slf4j.Slf4j;
//import org.springframework.beans.factory.annotation.Autowired;
//import org.springframework.kafka.core.KafkaTemplate;
//import org.springframework.stereotype.Component;
//
//import java.util.Date;
//
//@Slf4j
//@Component
//public class KafkaUtils {
//
//    @Autowired
//    private KafkaTemplate kafkaTemplate;
//
//    public void sendMsg(Long type, String topic, String msgJson){
//        Message<String> msg1 = new Message<>();
//        msg1.setType(type);//消息类型
//        msg1.setTopic(topic); //消息topic
//        msg1.setUserObject(msgJson);
//        msg1.setAddtional("");
//        msg1.setMessageNo(new Date().getTime());
//        try {
////            MessageClient.getInstance().send(msg1);
//            //首字节会被截取用来进行逻辑处理，这里直接赋值为 空格
//            kafkaTemplate.send(topic, " "+JSON.toJSONString(msg1));
//
//            log.debug("消息类型：{}，消息主题：{}，消息内容：{}，发送kafka消息成功！", type, topic, msgJson);
//        } catch (Exception e) {
//            e.printStackTrace();
//            log.debug("消息类型：{}，消息主题：{}，消息内容：{}，发送kafka消息出错：{}", type, topic, msgJson, e.getMessage());
//        }
//    }
//
//
//
//}
